🎖️GitЯра🎖️
Node / meshtastic / Meshtastic-Android / files / core / testing / src / commonMain / kotlin / org / meshtastic / core / testing / FakeCommandSender.kt
Displaying Raw • Download
core/testing/src/commonMain/kotlin/org/meshtastic/core/testing/FakeCommandSender.kt 41414f832f938b655c97bc07509bc140ea16e2a3 (41414f83) Text, 7.37 KB
T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.core.testing
Tff7b72import T7ee787org.meshtastic.core.common.util.nowMillis
Tff7b72import T7ee787org.meshtastic.core.model.DataPacket
Tff7b72import T7ee787org.meshtastic.core.model.MessageStatus
Tff7b72import T7ee787org.meshtastic.core.model.Position
Tff7b72import T7ee787org.meshtastic.core.repository.AwaitedSendResult
Tff7b72import T7ee787org.meshtastic.core.repository.AwaitedSendStatus
Tff7b72import T7ee787org.meshtastic.core.repository.CommandSender
Tff7b72import T7ee787org.meshtastic.core.repository.PacketQueueRejectedException
Tff7b72import T7ee787org.meshtastic.proto.AdminMessage
Tff7b72import T7ee787org.meshtastic.proto.ChannelSet
Tff7b72import T7ee787org.meshtastic.proto.LocalConfig
T8b949e/** Shared recording [CommandSender] fake for tests that do not need transport behavior. */
Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4)
Tff7b72class T56d364FakeCommandSender Tb4b4b4:
Te6edf3BaseFakeTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3CommandSender Tb4b4b4{
Tff7b72data Tff7b72class T56d364AdminRequestTb4b4b4(
Tff7b72val Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4,
Tff7b72val Te6edf3requestIdTb4b4b4: Tffa657IntTb4b4b4,
Tff7b72val Te6edf3wantResponseTb4b4b4: Tffa657BooleanTb4b4b4,
Tff7b72val Te6edf3messageTb4b4b4: Te6edf3AdminMessageTb4b4b4,
Tff7b72val Te6edf3expectedConnectionVersionTb4b4b4: Tffa657Long? Tff7b72= Tff7b72nullTb4b4b4,
Tb4b4b4)
Tff7b72data Tff7b72class T56d364TelemetryRequestTb4b4b4(
Tff7b72val Te6edf3requestIdTb4b4b4: Tffa657IntTb4b4b4,
Tff7b72val Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4,
Tff7b72val Te6edf3typeValueTb4b4b4: Tffa657IntTb4b4b4,
Tff7b72val Te6edf3expectedConnectionVersionTb4b4b4: Tffa657Long? Tff7b72= Tff7b72nullTb4b4b4,
Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3mutableSentPackets Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3DataPacketTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3sentPacketsTb4b4b4: Te6edf3ListTff7b72<Te6edf3DataPacketTff7b72>
Tff7b72getTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3mutableSentPacketsTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3snapshotTb4b4b4(Tb4b4b4) Tb4b4b4}
Tff7b72private Tff7b72val Te6edf3mutableAdminRequests Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3AdminRequestTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3adminRequestsTb4b4b4: Te6edf3ListTff7b72<Te6edf3AdminRequestTff7b72>
Tff7b72getTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3mutableAdminRequestsTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3mutableTelemetryRequests Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3TelemetryRequestTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3telemetryRequestsTb4b4b4: Te6edf3ListTff7b72<Te6edf3TelemetryRequestTff7b72>
Tff7b72getTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3mutableTelemetryRequestsTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72var Te6edf3nextPacketId Tff7b72= T79c0ff1
Tff7b72var Te6edf3lastPassphraseTb4b4b4: Tffa657String? Tff7b72= Tff7b72null
Te6edf3private Tff7b72set
Tff7b72var Te6edf3lastBootsTb4b4b4: Tffa657Int Tff7b72= T79c0ff0
Te6edf3private Tff7b72set
Tff7b72var Te6edf3lastHoursTb4b4b4: Tffa657Int Tff7b72= T79c0ff0
Te6edf3private Tff7b72set
Tff7b72var Te6edf3lastMaxSessionSecondsTb4b4b4: Tffa657Int Tff7b72= T79c0ff0
Te6edf3private Tff7b72set
Tff7b72var Te6edf3lastDisableTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72false
Te6edf3private Tff7b72set
Tff7b72var Te6edf3lockNowCalledTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72false
Te6edf3private Tff7b72set
Tff7b72var Te6edf3awaitedAdminResultTb4b4b4: Te6edf3AwaitedSendResult Tff7b72=
Te6edf3AwaitedSendResultTb4b4b4(Te6edf3AwaitedSendStatusTb4b4b4.Te6edf3ACCEPTEDTb4b4b4, Te6edf3departureEpochAtDispatch Tff7b72= T79c0ff0Tb4b4b4)
Tff7b72var Te6edf3sendDataFailureTb4b4b4: Te6edf3PacketQueueRejectedException? Tff7b72= Tff7b72null
Tff7b72var Te6edf3commandFailureTb4b4b4: Te6edf3Exception? Tff7b72= Tff7b72null
Tff7b72init Tb4b4b4{
Te6edf3registerResetAction Tb4b4b4{
Te6edf3mutableSentPacketsTb4b4b4.Te6edf3clearTb4b4b4(Tb4b4b4)
Te6edf3mutableAdminRequestsTb4b4b4.Te6edf3clearTb4b4b4(Tb4b4b4)
Te6edf3mutableTelemetryRequestsTb4b4b4.Te6edf3clearTb4b4b4(Tb4b4b4)
Te6edf3nextPacketId Tff7b72= T79c0ff1
Te6edf3lastPassphrase Tff7b72= Tff7b72null
Te6edf3lastBoots Tff7b72= T79c0ff0
Te6edf3lastHours Tff7b72= T79c0ff0
Te6edf3lastMaxSessionSeconds Tff7b72= T79c0ff0
Te6edf3lastDisable Tff7b72= Tff7b72false
Te6edf3lockNowCalled Tff7b72= Tff7b72false
Te6edf3awaitedAdminResult Tff7b72= Te6edf3AwaitedSendResultTb4b4b4(Te6edf3AwaitedSendStatusTb4b4b4.Te6edf3ACCEPTEDTb4b4b4, Te6edf3departureEpochAtDispatch Tff7b72= T79c0ff0Tb4b4b4)
Te6edf3sendDataFailure Tff7b72= Tff7b72null
Te6edf3commandFailure Tff7b72= Tff7b72null
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffgetCurrentPacketIdTb4b4b4(Tb4b4b4)Tb4b4b4: Tffa657Long Tff7b72= Te6edf3nextPacketIdTb4b4b4.Te6edf3toLongTb4b4b4(Tb4b4b4)
Tff7b72override Tff7b72fun Td2a8ffgetCachedLocalConfigTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3LocalConfig Tff7b72= Te6edf3LocalConfigTb4b4b4(Tb4b4b4)
Tff7b72override Tff7b72fun Td2a8ffgetCachedChannelSetTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3ChannelSet Tff7b72= Te6edf3ChannelSetTb4b4b4(Tb4b4b4)
Tff7b72override Tff7b72fun Td2a8ffgeneratePacketIdTb4b4b4(Tb4b4b4)Tb4b4b4: Tffa657Int Tff7b72= Te6edf3nextPacketIdTff7b72+Tff7b72+
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsendDataTb4b4b4(Te6edf3pTb4b4b4: Te6edf3DataPacketTb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Te6edf3requireTb4b4b4(Te6edf3pTb4b4b4.Te6edf3dataType Tff7b72!Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffPort numbers must be non-zero!Ta5d6ff" Tb4b4b4}
Tff7b72if Tb4b4b4(Te6edf3pTb4b4b4.Te6edf3id Tff7b72=Tff7b72= T79c0ff0Tb4b4b4) Te6edf3pTb4b4b4.Te6edf3id Tff7b72= Te6edf3generatePacketIdTb4b4b4(Tb4b4b4)
Te6edf3sendDataFailureTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3failure Tff7b72-Tff7b72>
Te6edf3pTb4b4b4.Te6edf3status Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3ERROR
Tff7b72throw Te6edf3failure
Tb4b4b4}
Te6edf3pTb4b4b4.Te6edf3status Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3QUEUED
Te6edf3pTb4b4b4.Te6edf3time Tff7b72= Te6edf3nowMillis
Te6edf3mutableSentPackets Tff7b72+Tff7b72= Te6edf3pTb4b4b4.Te6edf3snapshotTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tff7b72private Tff7b72fun Te6edf3DataPacketTb4b4b4.Td2a8ffsnapshotTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3DataPacket Tff7b72= Te6edf3copyTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3also Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3errorMessage Tff7b72= Te6edf3errorMessage Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsendAdminTb4b4b4(Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3requestIdTb4b4b4: Tffa657IntTb4b4b4, Te6edf3wantResponseTb4b4b4: Tffa657BooleanTb4b4b4, Te6edf3initFnTb4b4b4: Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Te6edf3AdminMessageTb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Te6edf3mutableAdminRequests Tff7b72+Tff7b72= Te6edf3AdminRequestTb4b4b4(Te6edf3destNumTb4b4b4, Te6edf3requestIdTb4b4b4, Te6edf3wantResponseTb4b4b4, Te6edf3initFnTb4b4b4(Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsendAdminForConnectionTb4b4b4(
Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3expectedConnectionVersionTb4b4b4: Tffa657LongTb4b4b4,
Te6edf3requestIdTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3wantResponseTb4b4b4: Tffa657BooleanTb4b4b4,
Te6edf3initFnTb4b4b4: Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Te6edf3AdminMessageTb4b4b4,
Tb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Te6edf3mutableAdminRequests Tff7b72+Tff7b72= Te6edf3AdminRequestTb4b4b4(Te6edf3destNumTb4b4b4, Te6edf3requestIdTb4b4b4, Te6edf3wantResponseTb4b4b4, Te6edf3initFnTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3expectedConnectionVersionTb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffsendAdminImmediateTb4b4b4(Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3initFnTb4b4b4: Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Te6edf3AdminMessageTb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Te6edf3mutableAdminRequests Tff7b72+Tff7b72= Te6edf3AdminRequestTb4b4b4(Te6edf3destNumTb4b4b4, Te6edf3requestId Tff7b72= T79c0ff0Tb4b4b4, Te6edf3wantResponse Tff7b72= Tff7b72falseTb4b4b4, Te6edf3message Tff7b72= Te6edf3initFnTb4b4b4(Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsendAdminAwaitResultTb4b4b4(
Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3requestIdTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3wantResponseTb4b4b4: Tffa657BooleanTb4b4b4,
Te6edf3initFnTb4b4b4: Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Te6edf3AdminMessageTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3AwaitedSendResult Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Te6edf3mutableAdminRequests Tff7b72+Tff7b72= Te6edf3AdminRequestTb4b4b4(Te6edf3destNumTb4b4b4, Te6edf3requestIdTb4b4b4, Te6edf3wantResponseTb4b4b4, Te6edf3initFnTb4b4b4(Tb4b4b4)Tb4b4b4)
Tff7b72return Te6edf3awaitedAdminResult
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsendPositionTb4b4b4(Te6edf3posTb4b4b4: Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3PositionTb4b4b4, Te6edf3destNumTb4b4b4: Tffa657Int?Tb4b4b4, Te6edf3wantResponseTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffrequestPositionTb4b4b4(Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3currentPositionTb4b4b4: Te6edf3PositionTb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsetFixedPositionTb4b4b4(Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3posTb4b4b4: Te6edf3PositionTb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffrequestUserInfoTb4b4b4(Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffrequestTracerouteTb4b4b4(Te6edf3requestIdTb4b4b4: Tffa657IntTb4b4b4, Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffrequestTelemetryTb4b4b4(Te6edf3requestIdTb4b4b4: Tffa657IntTb4b4b4, Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3typeValueTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Te6edf3mutableTelemetryRequests Tff7b72+Tff7b72= Te6edf3TelemetryRequestTb4b4b4(Te6edf3requestIdTb4b4b4, Te6edf3destNumTb4b4b4, Te6edf3typeValueTb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffrequestTelemetryForConnectionTb4b4b4(
Te6edf3requestIdTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3typeValueTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3expectedConnectionVersionTb4b4b4: Tffa657LongTb4b4b4,
Tb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Te6edf3mutableTelemetryRequests Tff7b72+Tff7b72= Te6edf3TelemetryRequestTb4b4b4(Te6edf3requestIdTb4b4b4, Te6edf3destNumTb4b4b4, Te6edf3typeValueTb4b4b4, Te6edf3expectedConnectionVersionTb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffrequestNeighborInfoTb4b4b4(Te6edf3requestIdTb4b4b4: Tffa657IntTb4b4b4, Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tff7b72private Tff7b72fun Td2a8fffailCommandIfConfiguredTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3commandFailureTff7b72?.Te6edf3let Tb4b4b4{ Tff7b72throw Tffa657it Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffsendLockdownPassphraseTb4b4b4(
Te6edf3passphraseTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3bootsTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3hoursTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3maxSessionSecondsTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3disableTb4b4b4: Tffa657BooleanTb4b4b4,
Tb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Te6edf3lastPassphrase Tff7b72= Te6edf3passphrase
Te6edf3lastBoots Tff7b72= Te6edf3boots
Te6edf3lastHours Tff7b72= Te6edf3hours
Te6edf3lastMaxSessionSeconds Tff7b72= Te6edf3maxSessionSeconds
Te6edf3lastDisable Tff7b72= Te6edf3disable
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffsendLockNowTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3failCommandIfConfiguredTb4b4b4(Tb4b4b4)
Te6edf3lockNowCalled Tff7b72= Tff7b72true
Tb4b4b4}
Tb4b4b4}
Served by rngit 1.5.0 - Generated in 0.08s